package com.wudizaba.nb.controller;

import com.wudizaba.nb.service.serviceImpl.kafkaProviderServiceImpl;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping(value = "/kafkaProvider")
@RequiredArgsConstructor
public class kafkaProviderController {
    private final kafkaProviderServiceImpl kafkaProviderService;

    @GetMapping(value = "/send")
    public String send(){
        System.out.println("kafkaProviderController调用");
        kafkaProviderService.sendMessage();
        return "send";
    }
}
